package utils;

import com.hw.model.MetricDataBody;
import lombok.AllArgsConstructor;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction;

import java.util.List;
import java.util.Map;

public class CustomKafkaSourceFunction extends RichParallelSourceFunction<List<MetricDataBody>> {

    public CustomKafkaSourceFunction(Map<String, String> config) {
    }

    @Override
    public void open(Configuration parameters) throws Exception {
    }

    @Override
    public void run(SourceContext<List<MetricDataBody>> sourceContext) throws Exception {

    }

    @Override
    public void cancel() {

    }
}
